import com.znyj.servlet.kafka.KafkaClt;


/**
 * Created by gaoliwei02 on 2017/10/9.
 */
public class test_kafka {
    public static void main(String[] args) {
        KafkaClt kafkaClt = new KafkaClt("101.236.32.51:9092");
        kafkaClt.sendMsg("testpan", "sdfsafdas");
        try {
            Thread.sleep(1000);
        } catch (InterruptedException e) {
            e.printStackTrace();
        }
    }


}
